﻿/*************************************************************************************

- CLR版本：        4.0.30319.42000
- 类 名 称：       TaskTool
- 机器名称：       YTE
- 命名空间：       LD.Tool.Other
- 文 件 名：       TaskTool
- 创建时间：       2022/6/14 12:03:04
- 作    者：       YTE
- 说   明：
- 修改时间：
- 修 改 人：
  *************************************************************************************/

using LD.Host;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace LD.Tool
{
    [Tool(FrmParam = "TaskToolFrm", Text = "任务", ToolType = ToolEnum.Other)]
    public class TaskTool : BaseTool
    {
        public override OpResult Execute(TB_Tool model)
        {
            stopwatch.Start();
            try
            {
                if (!string.IsNullOrEmpty(model.Param))
                {
                    List<Task> tasks = new List<Task>();
                    List<TaskToolModel> models = Newtonsoft.Json.JsonConvert.DeserializeObject<List<TaskToolModel>>(model.Param);
                    foreach (var item in models)
                    {
                        var task = Task.Run(() => ExceTask(item));
                        if (item.Wait)
                            tasks.Add(task);
                    }

                    Task.WaitAll(tasks.ToArray());

                    isSuccess = true;
                }
                else
                    message = "任务未指定";
            }
            catch (Exception ex)
            {
                isSuccess = false;
                message = ex.Message;
            }
            finally
            {
                stopwatch.Stop();
            }
            return new OpResult() { IsSuccess = isSuccess, Message = "", ExecuteTime = stopwatch.ElapsedMilliseconds };
        }
        private void ExceTask(TaskToolModel model)
        {
            var list = Appbus.PartNo.Config.Flow
                .Where(p => p.Name == model.Flow && p.FlowType == (int)FlowType.流程)
                .OrderBy(p => p.Sort)
                .FirstOrDefault();
            foreach (var item in list.Tools)
            {
                if (item.Enabled)
                {
                    Type type = Type.GetType("LD.Tool." + item.ClassName);
                    if (type != null)
                    {
                        BaseTool tool = (BaseTool)Activator.CreateInstance(type);
                        if (tool != null)
                        {
                            var opResult = tool.Execute(item);
                            if (!opResult.IsSuccess)
                                return;
                        }
                    }
                }
            }
        }
    }
}
